package cn.tedu.m1;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Producter {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂,并设置连接信息
        ConnectionFactory f1 = new ConnectionFactory();
            f1.setHost("192.168.64.140");
            f1.setPort(5672);
            f1.setUsername("admin");
            f1.setPassword("admin");
        Connection con = f1.newConnection(); //连接
        Channel c = con.createChannel(); //通信的通道
        //创建helloworld-XQ队列
        //如果服务器端，队列已经存在，就不会重复的创建
        //queueDeclare方法参数说明：(1)队列名、（2）是否是非持久队列（3）是否是排他队列（4）是否是自动删除队列（5）其他参数属性
        c.queueDeclare("helloworld-XQ",false,false,false,null);

        //向helloworld-XQ队列发送消息
        //basicPublish方法参数说明：（1）""表示是默认的交换机、（3）消息的其他属性配置
        c.basicPublish("", "helloworld-XQ", null, "helloworld".getBytes());
        System.out.println("消息已发送");
    }
}
